package com.xbongbong.workflow.rabbitmq.binders;

import com.xbongbong.workflow.rabbitmq.constant.WorkflowMqConsumerConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * workflow 消息队列
 * @author 魏荣杰
 *
 */
@Service("workflowMqConsumerBinder")
public interface WorkflowMqConsumerBinder {

    @Input(WorkflowMqConsumerConstant.WORKFLOW_START_INPUT)
    SubscribableChannel workflowStartInput();
//    @Output(WorkflowMqConsumerConstant.WORKFLOW_START_OUTPUT)
//    MessageChannel workflowStartOutput();

    @Input(WorkflowMqConsumerConstant.WORKFLOW_OPERATOR_INPUT)
    SubscribableChannel workflowOperatorInput();

//    @Output(WorkflowMqConsumerConstant.WORKFLOW_OPERATOR_OUTPUT)
//    MessageChannel workflowOperatorOutput();
    /**
     * 工作流无审批 消费者
     * @return
     */
    @Input(WorkflowMqConsumerConstant.WORKFLOW_OPERATOR_NO_APPROVE_INPUT)
    SubscribableChannel workflowOperatorNoApproveInput();
    /**
     * 工作流无审批 生产者
     * @return
     */
//    @Output(WorkflowMqConsumerConstant.WORKFLOW_OPERATOR_NO_APPROVE_OUTPUT)
//    MessageChannel workflowOperatorNoApproveOutput();
}
